package com.java.code.kafka;

/**
 * @author weichuanyuan
 * @e-mail wei.cy@bsoft.com.cn
 * @date 2021/10/19 21:33
 * @package com.java.code.kafka
 * @description
 */
public interface MQProducer {
    void start();

    void shutdown();

    boolean send(MQMessage<?> mqMessage);
}
